package com.xiaoyilin.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Direct模式
 * 需要在配置Queue的时候,指定一个键,使其和交换机绑定
 * Direct模式相当于一对一模式
 * 一个消息被发送者发送后,会被转发到一个绑定的消息队列中,然后被一个接收者接收!
 */
@Configuration
public class RabbitDirectConfig {

    @Bean("myDirectQueue")
    public Queue myDirectQueue() {
        //声明一个队列时自动绑定到默认交换器，并以队列名称作为路由键
        return new Queue("my.direct.queue");
    }


}
